package com.project.KafkaRoute.executor;

import org.apache.kafka.clients.consumer.ConsumerRecords;

public interface KafkaListenerConcurrently {

    Boolean consumeMessage(ConsumerRecords<String,String> msg);

}
